<?php

include_once "ConexionBD.php";
include_once "../negocio/Propiedad.php";

class PropiedadSQL{

    private $sql;


    function PropiedadSQL() {$this->sql = ConexionBD::getInstancia();}

    public function ingresarDatos(&$obj){

        $conn = $this->sql->getConexion();


        $sql="insert into PROPIEDAD values(nextval('propiedad_sec'), '".$obj->getDireccion()."', '".$obj->getSuperficie()."', '".$obj->getUnidadmedidasup()."', '".$obj->getCliente()."', '".$obj->getEmpresa()."')";


        if (!pg_query( $conn , $sql )){
            //die("Error de conexion. ". pg_last_error());
            return 0;
        }
        else return 1;
        pg_close($conn);
    }

    public function modificarDatos(&$obj){

        $sql=   "UPDATE PROPIEDAD
                SET direccion='".$obj->getDireccion()."', superficie='".$obj->getSuperficie()."', unidadmedidasup='".$obj->getUnidadmedidasup()."', cliente='".$obj->getCliente()."', empresa='".$obj->getEmpresa()."'
                WHERE id_pripiedad='".$obj->getId_pripiedad()."'";


        $conn = $this->sql->getConexion();
        if (!pg_query( $conn , $sql )){
            die("Error de conexion. ". pg_last_error());
        }
        pg_close($conn);
    }

    public function buscarDatos(&$obj){

        $sql=   "SELECT *
                FROM PROPIEDAD v, CLIENTE c
                WHERE v.cliente = c.rut and c.rut like '%".$obj->getRut()."%'
                AND UPPER(v.nombre) like UPPER('%".$obj->getNombres()."%')
                AND UPPER(v.apellido_p) like UPPER('%".$obj->getApellido_p()."%')
                AND UPPER(v.apellido_m) like UPPER('%".$obj->getApellido_m()."%')
                ORDER BY p.rut ASC";


        $resultado = $this->sql->ejecutarSql($sql);

        return $resultado;
    }

}

?>